Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------


Commit 354e1932dc0e1f3a97b7d70e05d634170b283c22


Parents : 093d4f1
Author : Mark Qvist <mark@unsigned.io>
Date : 2021-10-03T10:24:24+02:00

Sync sequence set up

Changes

1 files changed, 4 insertions(+), 0 deletions(-)


Diff

diff --git a/LXMF/LXMF.py b/LXMF/LXMF.py
index cccad31..c69a321 100644
--- a/LXMF/LXMF.py
+++ b/LXMF/LXMF.py
@@ -547,6 +547,7 @@ class LXMPeer:
# TODO: Remove
RNS.log("Sending sync request to peer")
self.link.request(LXMPeer.OFFER_REQUEST_PATH, unhandled_ids, response_callback=self.offer_response, failed_callback=self.request_failed)
+ self.state = LXMPeer.REQUEST_SENT
else:
# TODO: Remove
RNS.log("No unsynced messages")
@@ -570,8 +571,10 @@ class LXMPeer:
if response == LXMPeer.ERROR_NO_IDENTITY:
if self.link != None:
+ RNS.log("Remote peer indicated that no identification was received, retrying...", RNS.LOG_DEBUG)
self.link.indentify()
self.state = LXMPeer.LINK_READY
+ self.sync()
elif response == False:
# Peer already has all advertised messages
@@ -631,6 +634,7 @@ class LXMPeer:
def link_established(self, link):
self.link.identify(self.router.identity)
self.state = LXMPeer.LINK_READY
+ self.sync()
def link_closed(self, link):
self.link = None


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────